package org.example.bean;

import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
import java.sql.Timestamp;
public class KafkaJsonData implements Serializable {
    // 这里使用到 com.fasterxml.jackson 包下的解析库中的注解,将json中的字段key和当前 KafkaJsonData 实体类中的属性进行绑定,用于做字段映射.
    // 换一句话说: 注解中标识的就是: json字符串中的字段,如果当前json字符串中的值发生变化后,只需要改这个注解中的值即可.
    @JsonProperty("s_train_id")
    private String sTrainId;
    private String CX;
    @JsonProperty("phm_mc")
    private String phmMc;
    @JsonProperty("phm_lb")
    private String phmLb;
    @JsonProperty("GZKSSJ_UP")
    private Timestamp gzkssjUp;
    @JsonProperty("phm_bjwz")
    private String phmBjwz;
    private String LJ;
    private String ljjc;
    @JsonProperty("LJ_ID")
    private String ljId;
    private String PSD;
    private String psdjc;
    @JsonProperty("PSD_ID")
    private String psdId;
    @JsonProperty("phm_xt")
    private String phmXt;
    @JsonProperty("phm_xtbm")
    private String phmXtbm;
    @JsonProperty("phm_xtpjm")
    private String phmXtpjm;
    @JsonProperty("phm_bj")
    private String phmBj;
    @JsonProperty("phm_bjbm")
    private String phmBjbm;
    @JsonProperty("phm_pjm")
    private String phmPjm;
    private String pjxlh;
    private String pjdjm;
    private String IDX;
    private String SOURCE;
    @JsonProperty("GZDM_WM")
    private String gzdmWm;
    @JsonProperty("GZMC")
    private String gzmc;
    @JsonProperty("zj_ms")
    private String zjMs;
    @JsonProperty("zj_fa")
    private String zjFa;
    private Timestamp cksj;
}
